package com.songjia.stream.producer;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.SubscribableChannel;

/**
 * 
 * 
 * @Description: 自定义接口
 *
 * @author: songjia
 * @date: 2018年3月27日 下午3:43:37
 */
public interface SendToBinderReverse {

	String OUTPUT = "sendtoInput";// 消费者绑定的监听通道为sendtoInput，所以生产者的output通道指定为sendtoInput

	String INPUT = "sendtoOutput";// 消费者反馈信息的通道为sendtoOutput，所以生产者的input通道指定为sendtoOutput

	/**
	 * 新建名为 “sendtoInput” 的输出通道【发送消息用】
	 * 
	 * @return
	 */
	@Output(OUTPUT)
	SubscribableChannel output();

	/**
	 * 新建名为 “sendtoOutput” 的输入通道【被监听，消费消息】
	 * 
	 * @return
	 */
	@Input(INPUT)
	SubscribableChannel input();

}
